//package com.wulaobo.test;
//
//import com.wulaobo.pojo.Event;
//import org.apache.flink.streaming.api.datastream.DataStream;
//import org.apache.flink.streaming.api.datastream.DataStreamSource;
//import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;
//
//import java.util.ArrayList;
//
//public class DataStreamDemo1 {
//
//    public static void main(String[] args) throws Exception {
//        StreamExecutionEnvironment env =
//                StreamExecutionEnvironment.getExecutionEnvironment();
//        env.setParallelism(1);
//
//        ArrayList<Event> clicks = new ArrayList<>();
//        clicks.add(new Event("Mary","./home",1000L));
//        clicks.add(new Event("Bob","./cart",2000L));
//        DataStream<Event> stream = env.fromCollection(clicks);
//
//        DataStreamSource<Event> stream2 = env.fromElements(
//                new Event("Mary", "./home", 1000L),
//                new Event("Bob", "./cart", 2000L)
//        );
//
//        DataStreamSource<String> stringDataStreamSource = env.readTextFile("input/clicks.csv");
//
//        stream.print("1");
//        stream2.print("2");
//        stringDataStreamSource.print("3");
//        env.execute();
//    }
//
//}
